package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.AIBinderConstant;
import com.xbongbong.pro.rabbitmq.constant.CostRecalculationConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

/**
 * @Description: AI消息发送 消息队列
 * @Author: jiping.yang
 * @Date: 2022-09-15  11:24
 * @version: v1.0
 **/
@Service("aiConsumerBinder")
public interface AIConsumerBinder {

    /**
     * AI消息发送 消息队列
     */
    @Input(AIBinderConstant.AI_INPUT)
    SubscribableChannel aiInput();
}
